//package com.leyou.config;
//
//
//import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import redis.clients.jedis.HostAndPort;
//import redis.clients.jedis.JedisCluster;
//
//import java.util.HashSet;
//import java.util.Set;
//
//@Configuration
//public class JedisClusterConfig {
//
//    @Autowired
//    private JedisProperties redisProperties;
//
//    /**
//     * 这里返回的JedisCluster是单例的
//     * 并且可以直接注入到其他类中去使用
//     *
//     * @return JedisCluster的单例
//     */
//    @Bean
//    public JedisCluster getJedisCluster() {
//
//
//        String[] serverArray = redisProperties.getClusterNodes().split(",");
//
//        Set<HostAndPort> nodes = new HashSet<>();
//
//        for (String ipPort : serverArray) {
//            String[] ipPortPair = ipPort.split(":");
//            nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));
//        }
//        return new JedisCluster(nodes, redisProperties.getCommandTimeout(), redisProperties.getSoTimeout(), redisProperties.getMaxAttempts(), new GenericObjectPoolConfig());// 需要密码连接的创建对象方式
//
//
//    }
//}
